package com.zjc.mymq.client.async.event.spi.listener;

import com.zjc.mymq.client.async.event.model.BrokerConnectionClosedEvent;
import com.zjc.mymq.common.event.Listener;


/**
 * @author zjc
 * @date Created at 2024/7/16
 *  broker链接断开监听器
 */
public class BrokerConnectionClosedListener implements Listener<BrokerConnectionClosedEvent> {

    @Override
    public void onReceive(BrokerConnectionClosedEvent event) throws Exception {
        String brokerReqId = event.getBrokerReqId();
        System.out.println("channel断开：" + brokerReqId);
    }
}
